import java.util.concurrent.ArrayBlockingQueue;

import java.net.*;
public class db_query_queue {
	private ArrayBlockingQueue<db_session> oQueue =  new ArrayBlockingQueue<db_session>(100);
	public db_lock oLock;
	db_query_queue () {
		oLock = new db_lock();
	}
	public void add_query(Socket oSock) throws Exception{
		oQueue.put(new db_session(oSock));
	}
	public db_session get_query() throws Exception{
		return oQueue.take();
 
	}
}
